package cn.itcast.concurrent.disruptor;


import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

/**
 * 单一写模式
 *
 */
public class singleProductorLongEventMain {
    public static void main(String[] args) throws Exception {
        LongEventFactory factory = new LongEventFactory();
        //.....// Construct the Disruptor with a SingleProducerSequencer 
        Executor executor = Executors.newCachedThreadPool();
        // Specify the size of the ring buffer, must be power of 2.
        int bufferSize = 1024;// Construct the Disruptor



    }
}